package com.cmsz.collection.service;

import com.cmsz.collection.bean.LogBean;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.elasticsearch.action.bulk.BulkRequest;

import java.text.ParseException;

public interface InfoFilter {

    BulkRequest infoToLog(ConsumerRecord record, BulkRequest bulkRequest) throws ParseException;
}
